package xuecheng.tool.mq.alibaba.rocket;

import java.lang.annotation.*;

/**
 * 自定义 RocketMq 主题订阅监听注解
 *
 * @author PengXueCheng
 * @version 1.0.0
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RocketMqMessageListener {

    /**
     * 一级主题
     *
     * @return
     */
    String topic();

    /**
     * 二级主题
     *
     * @return
     */
    String tag() default "*";

    /**
     * 消费者所在组
     *
     * @return
     */
    String consumerGroup();

    /**
     * 默认会读取 cpx.rocketmq.name-server 属性值
     *
     * @return
     */
    String nameServer() default "";

}